package com.serwer;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import com.test.parse;

public class Download {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		
		String sql="SELECT * FROM notowania";
	    

	    try {
	        Class.forName("com.mysql.jdbc.Driver");
	        Connection con= (Connection) DriverManager.getConnection("jdbc:mysql://localhost:3306/BROKER","root","");
	        Statement stmt=con.createStatement();
	        ResultSet rs = stmt.executeQuery(sql);
	        String Id = null;
	        String Data = null;
	        String Nazwa = null;
	        String kursBiezacy = null;
	        String KursOdniesienia = null;
	        String Zmiana = null;
	        String KursOtwarcia = null;
	        String KursMin = null;
	        String KursMax = null;
	        String Wolumen = null;
	        String Wartosc = null;
	        	        
	        String allId = "";
	        String allData = "";
	        String allNazwa = "";
	        String allkursBiezacy = "";
	        String allKursOdniesienia = "";
	        String allZmiana = "";
	        String allKursOtwarcia = "";
	        String allKursMin = "";
	        String allKursMax = "";
	        String allWolumen = "";
	        String allWartosc = "";
	        
	       while (rs.next())
	      {
        //list sql
	    	   Id = rs.getString("id_notowania");
	    	   Data = rs.getString("data");
	    	   Nazwa = rs.getString("nazwa");
	    	   kursBiezacy = rs.getString("kurs_biezacy");
	    	   KursOdniesienia = rs.getString("kurs_odniesienia");
	    	   Zmiana = rs.getString("zmiana");
	    	   KursOtwarcia = rs.getString("kurs_otwarcia");
	    	   KursMin = rs.getString("kurs_min");
	    	   KursMax = rs.getString("kurs_max");
	    	   Wolumen = rs.getString("wolumen");
	    	   Wartosc = rs.getString("wartosc");
	    	   
	    	   allId +=Id+';';
	    	   allData+=Data+';';
	    	   allNazwa+=Nazwa+';';
	    	   allkursBiezacy+=kursBiezacy+';';
	    	   allKursOdniesienia+=KursOdniesienia+';';
	    	   allZmiana+=Zmiana+';';
	    	   allKursOtwarcia+=KursOtwarcia+';';
	    	   allKursMin+=KursMin+';';
	    	   allKursMax+=KursMax+';';
	    	   allWolumen+=Wolumen+';';
	    	   allWartosc+=Wartosc+';';
	    	   
	    	   
	    	  System.out.println(Id + " -" + kursBiezacy);
	             
	      }
	       //tylko do testu
	       System.out.println("PRZED");
	       System.out.println(allkursBiezacy);
	       System.out.println(allId);
	       System.out.println(allNazwa);
	       System.out.println(allData);
	       System.out.println(allKursOdniesienia);
	       System.out.println(allZmiana);
	       System.out.println(allKursOtwarcia);
	       System.out.println(allKursMin);
	       System.out.println(allKursMax);
	       System.out.println(allWolumen);
	       System.out.println(allWartosc);
	       /* teraz mozna wyslac to kolejka*/
	       ProducerNotowSend PtNoSe = new ProducerNotowSend(allId, allData,
	    		   allNazwa, allkursBiezacy, allKursOdniesienia, allZmiana, allKursOtwarcia, allKursMin, allKursMax,
	    		   allWolumen, allWartosc);
	     
	       }
	    catch(Exception e) {
	    
	    }
	}
}
